package com.winchain.provider.expiration.rx;

import java.util.concurrent.CountDownLatch;
import org.apache.commons.logging.Log;
import org.springframework.stereotype.Component;

@Component
public class BillExpAfterTaskSubsciber extends TransactionNewSubscriber<BillExpirationEvent> {
	public void execute(BillExpirationEvent event) {
		CountDownLatch counter = (CountDownLatch) event.getValue("counter");
		try {
			counter.await();
			this.logger.info("--------ExpTask excute end--------");
		} catch (InterruptedException e) {
			this.logger.error(e);
		}
	}
}
